package com.example.rabbitspringamqp.listener.delegate;

import java.util.Map;

/**
 * @author haitao
 * @date 2021/7/14 9:05 上午
 * @desc MessageListenerAdapter（消息监听适配器）的自定义消息监听处理类
 */
public class MessageDelegate {


    public final static String QUEUE1_METHOD_NAME = "onQueue1Message";

    public final static String QUEUE2_METHOD_NAME ="onQueue2Message";

    /**MessageListenerAdapter底层默认处理方法为handlerMessage，然后反射*/
    public void onMessage(String message){
        System.out.println("自定义消息监听处理："+message);
    }

    public void onQueue1Message(Map message){
        System.out.println("自定义某个队列（）的消息监听处理："+message);
    }

    public void onQueue2Message(Map message){
        System.out.println("自定义某个队列（）的消息监听处理："+message);
    }

    public void onJackson2Message(Map messageMap){
        System.out.println("Jackson2MessageConverter将参数转为了Map："+messageMap);
    }


}